package com.train.streamreceive.sinks;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.SubscribableChannel;

public interface Sink2 {
    String INPUT = "input_2";

    /**
     * @return input channel.
     */
    @Input(INPUT)
    SubscribableChannel input_2();
}
